# celery的任务必须写在tasks.py的文件中，别的文件名称不识别!!!
from mycelery.main import app
from lufffyapi.libs.yuntongxun.sms import CCP
from lufffyapi.settings import constants
import logging

log = logging.getLogger('django')


# @app.task(name="send_sms")  # name表示设置任务的名称，如果不填写，则默认使用函数名(路径)做为任务名
# def send_sms():
#     return "发送短信任务"
#
#
# @app.task  # name表示设置任务的名称，如果不填写，则默认使用函数名做为任务名
# def send_sms2():
#     return "发送短信任务2!!!"

@app.task(name='send_sms')
def send_sms(mobile, sms_code):
    ccp = CCP()
    ret = ccp.send_template_sms(mobile, [sms_code, constants.SMS_EXPIRE_TIME // 60], 1)
    if not ret:
        log.error(f"用户注册短信发送失败！手机号：{mobile}")
